package com.shujia.useraction

import com.shujia.utils.SparkTool
import org.apache.spark.sql.{DataFrame, SparkSession}

// 描述数据的处理过程
trait UserActionBase {

  var df: DataFrame = _

  val spark: SparkSession = SparkTool.getSparkSession(this.getClass.getName.replace("$", ""))


  // 加载数据
  def load(): DataFrame

  def load(path: String, day: String): DataFrame


  // 处理数据
  def process(): Unit


  // 保存数据
  def save(): Unit

}
